package com.csc.producer;


/**
 * @description:
 * @author: ChenShuCheng
 * @create: 2021-07-04 20:19
 **/
public class Produce {


    public void doProduce(String key,String msg){
//        Broker.setTopic(key,msg);
    }


    public static void start() {
        Produce producer = new Produce();
        String topic = "天问一号";
        producer.doProduce(topic,"火箭主体");
        producer.doProduce(topic,"火箭发动机");
        producer.doProduce(topic,"舱室");
        int count = 0;
        while (true){
            producer.doProduce(topic,""+count);
            count++;
        }
    }
}
